//package org.ddd.pattern.event.springboot.rocketmq.consume.distribute;
//
//import org.ddd.pattern.event.idempotent.EventIdempotentService;
//import org.springframework.context.ApplicationEvent;
//import org.springframework.context.ApplicationListener;
//
//import java.util.Objects;
//
///**
// * 幂等处理
// *
// * @date 2025-08-23 13:49
// */
//public class IdempotentListenerMethodAdapter implements ApplicationListener {
//
//    private EventIdempotentService eventIdempotentService;
//    private final ApplicationListener    proxy;
//
//    public IdempotentListenerMethodAdapter(ApplicationListener proxy) {
//        this.proxy = Objects.requireNonNull(proxy);
//    }
//
//    @Override
//    public void onApplicationEvent(ApplicationEvent applicationEvent) {
//        eventIdempotentService
//        proxy.onApplicationEvent(applicationEvent);
//    }
//
//}
